如果内置的Catalog类型无法满足您的业务需求,您可以使用自定义Catalog类型。本文为您介绍如何配置自定义Catalog。
注意事项
自定义Catalog类型间的名称需要唯一。
当自定义Catalog类型的名称与内置的名称相同时,优先使用您的自定义Catalog。
删除自定义Catalog类型后,该自定义Catalog类型下注册的Catalog也将被删除。
创建并使用自定义Catalog
进入数据管理页面。
登录实时计算控制台。
单击目标工作空间操作列下的控制台。
在左侧导航栏,单击数据管理。
单击创建Catalog,在自定义Catalog页签,单击创建自定义Catalog类型。
在创建自定义Catalog类型对话框,配置自定义Catalog类型信息。
方式
说明
上传文件
单击选择文件,选择您的目标自定义Catalog类型文件。自定义Catalog类型开发详情请参见Catalogs。
外部URL
填写外部URL信息。当需要使用其他服务上存在的JAR文件时,可以使用外部URL功能获取JAR文件。
说明仅支持以下两类外部URL:
开通Flink工作空间时选择的OSS Bucket地址。您可以在实时计算管理控制台目标工作空间详情中查看绑定的OSS Bucket。
实时计算Flink版可以访问且被允许访问(公共读或被授予权限)的其他外部存储系统地址。
单击下一步。
确认Properties信息后,单击确定。
在自定义Catalog页签,单击您刚创建好的自定义Catalog类型名称,单击下一步。
填写Catalog代码信息及参数值后,单击确定,创建Catalog。
代码示例如下,您可以根据实际情况进行修改。
CREATE CATALOG `catalogname` --catalogname为创建的Catalog名称。 WITH ( 'type' = 'hologres-custom', --步骤5中的Catalog类型名称。 'endpoint' = 'yourEndpoint', --步骤5中required勾选的参数为必填WITH参数,下同。 'username' = 'yourUsername', 'password' = 'yourPassword', 'dbname' = 'yourDbname' );
说明Catalog名称建议添加反引号(``),否则当名称中包含
.
等字符时运行会报错。
查看或删除自定义Catalog类型
在数据管理页面,单击创建Catalog。
单击自定义Catalog页签,查看或删除自定义Catalog类型。
查看:鼠标悬浮在自定义Catalog类型名称上面,查看自定义Catalog类型JAR包路径、Catalog类型、创建时间和创建人等信息。
删除:单击目标自定义Catalog类型名称右侧的图标,单击确定。